ce5b82c88054bcfaf7b30d2e03392a2af2b6ed80,driver-core/src/test/java/com/datastax/driver/core/SpeculativeExecutionTest.java,SpeculativeExecutionTest,should_wait_until_all_executions_have_finished,#,158
Before Change
scassandras.node(1).primingClient()
// execution1 starts with host1, which will time out at t=1000
.prime(PrimingRequest.queryBuilder()
.withQuery("mock query")
.withFixedDelay(2000)
.withRows(row("result", "result1"))
.build());
// at t=1000, execution1 moves to host3, which eventually succeeds at t=1500
scassandras.node(3).primingClient()
After Change
scassandras.node(1).primingClient()
// execution1 starts with host1, which will time out at t=1000
.prime(PrimingRequest.queryBuilder()
.withQuery("mock query")
.withThen(then().withRows(row("result", "result1")).withFixedDelay(2000L))
.build());
// at t=1000, execution1 moves to host3, which eventually succeeds at t=1500
scassandras.node(3).primingClient()